package com.xl.flinkdemo.多流转换算子;

/**
 * connect算子：只能连接2条流
 * 将两条流合成一个流
 *
 * 两条流的数据类型都不一样，所以需要重写不同的map方法
 *
 * union：连接多条流：
 * 额外限制：多条流的类型必须一致，没有追加操作
 */
public class Transform_ConnectStream {

    //在分流操作中做的合流操作

}
